package com.andy.process.sink;


import org.apache.kafka.clients.consumer.Consumer;
import org.apache.kafka.clients.consumer.KafkaConsumer;

import java.util.Properties;

/**
 * Created by Administrator on 2017/9/13.
 */
public class KafkaConsumerSink {
    private Consumer<String, String> consumer;

    public KafkaConsumerSink(Properties prop) {
        consumer = new KafkaConsumer<String, String>(prop);
    }
}
